

use dev1;



drop table spark_task;
create table spark_task (
id text primary key,
spark_app_id text,
spark_app_state text,
created_timestamp timestamp,
last_updated_timestamp timestamp,
completed_timestamp timestamp);

insert into dev1.spark_task (id, spark_app_id, created_timestamp)
values ('id111', 'spark111', '2017-04-01T11:21:59.001+0000');

use livev1;
create table spark_task (
id text primary key,
spark_app_id text,
spark_app_state text,
created_timestamp timestamp,
last_updated_timestamp timestamp,
completed_timestamp timestamp);


